package com.mavenq.fly.utils.excelv4.processor;

/**
 * 流式数据处理接口
 */
public interface StreamingDataProcessor<T> {
    boolean processItem(T data, int rowIndex);
    default void onBatchComplete(int batchSize, int successCount) {}
    default void onComplete(long totalRows, long successRows) {}
    default void onError(Exception error) {
        System.err.println("流式处理发生错误: " + error.getMessage());
        error.printStackTrace();
    }
}